package queueasync;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * <p>
 * 异步多线程队列处理任务
 * </P>
 *
 * @author dingwen
 * @date 2021.12.10 15:12
 */
public class QueueAsyncTest {

    /**
     * 模拟8个任务处理线程处理1000个日志记录任务
     * 后期优化：可将多次任务汇聚，对数据库执行批量插入。节省与数据库连接会话的时间
     *
     * @param args arg游戏
     */
    public static void main(String[] args) {


        // 初始化任务管理
        TaskManagement  taskManagement = new TaskManagement(8);
        taskManagement.start();
        //辅助方法阻塞 阻塞完成后 后续回收线程
        List<Integer> ids = new ArrayList<>();

        for (int i = 0; i < 1000; i++) {
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            LogTask task = new LogTask(new LogEntity("test"+ i,new Date()));
            int add = taskManagement.add(task);
            ids.add(add);
        }

        ids.forEach(i ->{
            Object o = TaskManagement.resultMap.get(i);
            System.out.println(o);
        });
    }


}
